package com.cloudcanal.processor;

public class UserInfoConvert extends DataChangeModify {

	@Override
	public String tableName() {
		return "user_info";
	}

	@Override
	public String getPrepareStatementSql() {
		return "SELECT CONCAT('{\"user_name\": \"', name,'\", \"mobile_no\": \"', mobile_no, '\"}') as payload, 'user_info' as data_source FROM user.user_info where id = ?";
	}
}
